package com.qs.rocketmq.sc.service;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 只定义接口，无需写实现类，最终会生成代理对象
 */
public interface MySource {

    // 返回值为MessageChannel，可以用来作为生产者发送消息
    @Output("my_output")
    MessageChannel output();

}
